package com.langChain4j.model;

import dev.langchain4j.service.MemoryId;
import dev.langchain4j.service.UserMessage;
import reactor.core.publisher.Flux;

/**
 * @author linjun
 * @date 2025/10/15 17:17
 * @description
 */
public interface StreamAssistant {

    /**
     * 基于记忆对话
     * @param memoryId 记忆ID
     * @param message 对话消息
     * @return
     */
    Flux<String> memoryChat(@MemoryId String memoryId, @UserMessage String message);

}
